package cn.gwm.flink.streaming.function.process;

import cn.gwm.flink.streaming.strategy.termal.TermalVehicleCheckEvStrategy;
import cn.hutool.core.lang.Dict;
import org.apache.flink.streaming.api.functions.KeyedProcessFunction;
import org.apache.flink.util.Collector;

/**
 * 车端上传热失控事件处理函数
 * @author GW00283474
 */
public class TermalWarningEvVehicleCheckProcessFunction extends KeyedProcessFunction<String, Dict,Dict> {
    @Override
    public void processElement(Dict dict, KeyedProcessFunction<String, Dict, Dict>.Context context, Collector<Dict> out) throws Exception {
        Dict resultDict = TermalVehicleCheckEvStrategy.termalVehicleCheck(dict);
        out.collect(resultDict);
    }
}
